package util

import (
	"AcsGo/logger"

	_ "github.com/denisenkom/go-mssqldb"
	"github.com/jmoiron/sqlx"
)

var loggerl = logger.InitLog()

func ConnectDB(connString string) (*sqlx.DB, error) {

	// 数据库连接字符串
	// if connString == "" {
	// 	connString = "server=localhost;database=testdb;user id=testuser;password=testpass;port=1433"
	// 	loggerl.Error("数据库连接字符串为空,使用本地")
	// }

	// 打开数据库连接
	db, err := sqlx.Connect("sqlserver", connString)
	if err != nil {
		loggerl.Error("数据库连接失败", err)
		return nil, err
	}

	// 验证连接是否成功
	err = db.Ping()
	if err != nil {
		loggerl.Error("Ping数据库连接失败", err)
		return nil, err
	}

	return db, nil
}
